22c36ff1c6238bfb1b1386612ef17cb50ad68bb9,spi/backups/src/main/java/CounterService.java,CounterService,rollbackMigration,#PartitionMigrationEvent#,80

Before Change


    @Override
    public void rollbackMigration(PartitionMigrationEvent event) {
        if (event.getMigrationEndpoint() == MigrationEndpoint.DESTINATION) {
            Container container = containers[event.getPartitionId()];
            container.clear();
        }
    }

After Change


    public void rollbackMigration(PartitionMigrationEvent event) {
        if (event.getMigrationEndpoint() == MigrationEndpoint.DESTINATION) {
            int currentReplicaIndex = event.getCurrentReplicaIndex();
            if (currentReplicaIndex == -1 || currentReplicaIndex > 1) {
                clearPartitionReplica(event.getPartitionId());
            }
        }
    }